【flink1.20.0搭建】

# 安装java环境
tar -zxf jdk-8u431-linux-x64.tar.gz -C /usr/local/

# 添加环境变量
vim /etc/profile

# 将以下内容添加到文件末尾
#JAVA_HOME
export JAVA_HOME=/usr/local/jdk1.8.0_431
export CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar
export PATH=$PATH:$JAVA_HOME/bin

# 刷新环境变量
source /etc/profile

# 测试java是否部署成功
java -version

# 安装flink工具
tar -zxf flink-1.20.0-bin-scala_2.12.tgz -C /usr/local/

# 测试flink是否部署成功
/usr/local/flink-1.20.0/bin/flink -v

# 修改配置文件
#vim /usr/local/flink-1.17.1/flink-conf.yaml

# 根据提供的配置文件flink-conf.yaml，只需修改IP部分为本机IP
#jobmanager.rpc.address：
#taskmanager.host：
#rest.address：

# 上传配置文件，覆盖原有的，根据提供的配置文件config.yaml，只需修改（address、host）部分为本机IP
vim /usr/local/flink-1.20.0/conf/config.yaml 

# 创建数据存放目录
mkdir -p /usr/local/flink-1.20.0/flink-data

# 启动flink
/usr/local/flink-1.20.0/bin/start-cluster.sh

# 查看是否正常启动
jps
13605 Jps
12999 StandaloneSessionClusterEntrypoint
13564 TaskManagerRunner

# 浏览器访问 IP+8081 端口验证flink是否启动


# 安装flink任务管理平台

# 使用提供编译好的部署包和flink初始化sql文件
flink-streaming-platform-web.tar.gz
creat_flink_web.sql

# 解压部署包
tar -zxf flink-streaming-platform-web.tar.gz -C /usr/local/

# 修改配置文件（配置项修改成实际的MySQL数据库连接信息）
vim /usr/local/flink-streaming-platform-web/conf/application.properties

# jdbc信息
server.port=9084
spring.datasource.url=jdbc:mysql://192.168.1.13:3306/flink_web?serverTimezone=UTC&useUnicode=true&characterEncoding=utf-8&useSSL=false
spring.datasource.username=gtc_user
spring.datasource.password=GNkjcvIfHbFljkD2861MR3vRd4lB9l

# 执行初始化sql
docker cp ./creat_flink_web.sql mysql:/root
docker exec  -it mysql bash
mysql -uroot -p
create database flink_web;
use flink_web;
source /root/creat_flink_web.sql;

# 也可以使用navicat执行SQL文件，会自动创建名为"flink_web"的数据库

# 启动flink任务管理平台(启动需要一定时间，可以通过查看web日志来判断是否正常启动)
/usr/local/flink-streaming-platform-web/bin/deploy.sh start

# 浏览器访问 IP+9084 端口验证flink是否启动
默认账号密码为：admin/123456

# 成功登录后打开flink管理平台的系统设置，补全以下信息：
Flink客户端目录   /usr/local/flink-1.20.0/
Flink管理平台目录 /usr/local/flink-streaming-platform-web/
自动开启savepoint true
Flink服务HTTP地址 http://192.168.1.13:8081/